package com.haiyou.dc.kafka.kafka;

import com.haiyou.dc.kafka.config.Constant;
import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class KafkaSimpleConsumer {

    @KafkaListener(group = "test-group", topics = Constant.topic)
    public void consumer(String message) {
        log.info("consumer content = {}", message);

    }
}

